package es

//
//import (
//	"api/model/mysql"
//	"bytes"
//	"context"
//	"encoding/json"
//	"github.com/elastic/go-elasticsearch/v7/esapi"
//	"log"
//	"strconv"
//	"strings"
//	"sync"
//)
//
//func SyncGoodsToEs(goods string, goodsList []*mysql.Goods) {
//	var (
//		wg sync.WaitGroup
//	)
//
//	for _, goods := range goodsList {
//		wg.Add(1)
//
//		go func(goodsList []mysql.Goods) {
//			defer wg.Done()
//
//			// Build the request body.
//			data, err := json.Marshal(struct{ Title string }{Title: goods})
//			if err != nil {
//				log.Fatalf("Error marshaling document: %s", err)
//			}
//
//			// Set up the request object.
//			req := esapi.IndexRequest{
//				Index:      "goods",
//				DocumentID: strconv.Itoa(int(goods.ID)),
//				Body:       bytes.NewReader(data),
//				Refresh:    "true",
//			}
//
//			// Perform the request with the client.
//			res, err := req.Do(context.Background(), es)
//			if err != nil {
//				log.Fatalf("Error getting response: %s", err)
//			}
//			defer res.Body.Close()
//
//		}(goods)
//	}
//	wg.Wait()
//
//}
